export default class SocketService {
  /**
   * 单例
   */
  static instance = null
  static get Instance() {
    if (!this.instance) {
      this.instance = new SocketService()
    }
    return this.instance
  }
  // 业务类型和回调函数的对于关系
  //  定义一个对象 存储回调函数
  callBackMapping = {}

  // 和服务端连接的socket对象
  ws = null
  // 是否已经连接成功
  connected = false
  sendRetryCount = 0  //其实可以使用this.$nextClick()
  connectRetryCount = 0 // 重连次数, 重连次数越大, 下一次再发起重连的延时也就越长

  // 定义连接服务器的方法
  connect() {
    // 连接服务器
    if (!window.WebSocket) return console.log('您的浏览器不支持 WebSocket')
    // 使用接口地址
    this.ws = new WebSocket('ws:124.221.156.158:9998')
    // 连接成功的事件
    this.ws.onopen = () => {
      console.log('连接服务端成功了')
      this.connected = true
      this.connectRetryCount = 0
    }
    // ws  接收到消息的处理
    this.ws.onmessage = msg => {
      const recvData = JSON.parse(msg.data)
      const socketType = recvData.socketType
      // 判断有没有注册函数
      if (this.callBackMapping[socketType]) {
        if (recvData.action == 'getData') {
          let realData = recvData.data
          this.callBackMapping[socketType].call(this, realData)
        } else if (recvData.action == 'fullScreen') {
          this.callBackMapping[socketType].call(this, recvData)
        } else if (action == 'themeChange') {
        }
      }
      //  console.log('接受到的服务器的数据'+msg.data);
    }
    // 连接服务端失败
    this.ws.onerror = () => {
      console.log('连接服务端失败')
    }
    // 连接已关闭  当连接成功后:服务器关闭
    this.ws.onclose = () => {
      console.log('连接已关闭')
      setTimeout(() => {
        this.connectRetryCount++
        this.connect()
      }, 200 * this.connectRetryCount)
    }
  }

  // 发送数据
  send(data) {
    console.log('发送数据给服务器:')
    if (this.connected) {
      this.sendRetryCount = 0
      this.ws.send(JSON.stringify(data))
    } else {
      setTimeout(() => {
        this.sendRetryCount++
        this.send(data)
      }, 200 * this.sendRetryCount)
    }
  }
  // 回调函数的注册 socketType  回调函数的唯一标识
  registerCallBack(socketType, callBack) {
    // 往 callBackMap中存放回调函数
    this.callBackMapping[socketType] = callBack
  }
  // 取消某一个回调函数
  unRegisterCallBack(socketType) {
    this.callBackMapping[socketType] = null
  }
}
